//package com.core.system.config.transaction;
//
//import com.alibaba.fastjson.JSONObject;
//import com.core.system.service.impl.BaseService;
//import com.rocketmq.transaction.execult.TransactionExecute;
//import lombok.extern.slf4j.Slf4j;
//import org.apache.rocketmq.client.producer.SendResult;
//import org.apache.rocketmq.client.producer.SendStatus;
//import org.apache.rocketmq.common.message.Message;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.web.bind.annotation.RequestMapping;
//import org.springframework.web.bind.annotation.RestController;
//
//import java.util.UUID;
//
//
///**
// * @author xub
// * @Description: 订单服务相关接口
// * @date 2019/7/12 下午6:01
// */
//@Slf4j
//@RestController
//@RequestMapping("api/v1/common/order")
//public class OrderController extends BaseService {
//
//
//    @Autowired private TransactionExecute transactionExecute;
//
//    @Autowired private TransactionServiceImpl transactionService;
//
//
//
//
//    /**
//     * 商品下单接口
//     */
//    @RequestMapping("save")
//    public Object save(){
//
//        //通过uuid 当key
//        String uuid = UUID.randomUUID().toString().replace("_", "");
//
//        //封装消息
//        JSONObject msgJson = new JSONObject();
//        msgJson.put("productId", "1");
//        msgJson.put("total", "1");
//        String jsonString = msgJson.toJSONString();
//        transactionExecute.setTransactionService(transactionService);
//        Message message =  new Message("transaction_group", "transaction", jsonString.getBytes());
//        SendResult sendResult = transactionExecute.transactionExecute(message);
//        //发送消息 用 sendMessageInTransaction  第一个参数可以理解成消费方需要的参数 第二个参数可以理解成消费方不需要 本地事务需要的参数
//        System.out.printf("发送结果=%s, sendResult=%s \n", sendResult.getSendStatus(), sendResult.toString());
//        if (SendStatus.SEND_OK == sendResult.getSendStatus()) {
//            return "成功";
//        }
//        return "失败";
//    }
//
//}
//
